package pipeline;

/**
 * Created by Administrator on 2017/3/17.
 */
public class PipeException extends Exception{

    public final Pipe<?,?> sourcePipe;

    public final Object input;

    public PipeException(Pipe<?,?> sourcePipe,Object input,String message){
        super(message);
        this.sourcePipe=sourcePipe;
        this.input=input;
    }

    public PipeException(Pipe<?,?> sourcePipe,Object input,String message,Throwable cause){
        super(message,cause);
        this.sourcePipe=sourcePipe;
        this.input=input;
    }



}
